/*
  流：  一组有序的字节数据
*/
let fs = require('fs')
// 可读流 
let reasStream = fs.createReadStream('./data.json')
/*
事件
open   文件打开时执行
data  接收数据的时候执行
end    数据接收完成执行
error   读取失败的时候 执行
*/
/* reasStream.on('open', function (fd) {
  console.log("打开文件：", fd)
})
let str = ''
reasStream.on('data', function (chunk) {
  console.log("数据流：", chunk)
  reasStream.pause()  // 暂停
  str += chunk
})
reasStream.on('end', function () {
  console.log("读取完成：")
  console.log(str)
})
reasStream.on('error', function (err) {
  console.log("打开文件失败", err)
})
setTimeout(() => {
  reasStream.resume() // 重启
}, 3000); */


// let writeStream = fs.createWriteStream('./data2.txt')
// writeStream.write("ertywgsdfrgsdfg")

let writeStream = fs.createWriteStream('./data2.json')

reasStream.pipe(writeStream)
// 把可读流和可写流链接起来
